import axios from 'axios';

// 此方案主要有两个功能
// 1.请求发出后，后续重复请求取消不处理，等待第一次请求完成。
// 2.路由跳转后，上一个页面未完成请求全部清理.

// 一、取消重复请求
// axios.js
const pending = new Map();
/**
 * 添加请求
 * @param {Object} config
 **/
const addPending = (config) => {
  const url = [config.method, config.url, qs.stringify(config.data)].join('&');
  if (pending.has(url)) {
    // 如果 pending 中存在当前请求则取消后面的请求
    config.cancelToken = new axios.CancelToken((cancel) =>
      cancel(`重复的请求被主动拦截: ${url}`)
    );
  } else {
    // 如果 pending 中不存在当前请求，则添加进去
    config.cancelToken =
      config.cancelToken ||
      new axios.CancelToken((cancel) => {
        pending.set(url, cancel);
      });
  }
};
/**
 * 移除请求
 * @param {Object} config
 */
const removePending = (config) => {
  const url = [
    config.method,
    config.url.replace(config.baseURL, ''), // 响应url会添加域名，需要去掉与请求URL保持一致
    qs.stringify(JSON.parse(config.data)), // 需要与request的参数结构保持一致，request中是对象，response中是字符串
  ].join('&');
  if (pending.has(url)) {
    // 如果在 pending 中存在当前请求标识，取消当前请求，并且移除
    pending.delete(url);
  }
};

/* axios全局请求参数设置，请求拦截器 */
axios.interceptors.request.use(
  (config) => {
    addPending(config); // 将当前请求添加到 pending 中
    return config;
  },
  (error) => {
    return Promise.reject(error);
  }
);
// 响应拦截器即异常处理
axios.interceptors.response.use(
  (response) => {
    removePending(response.config); // 在请求结束后，移除本次请求
    return response;
  },
  (err) => {
    if (err && err.config) {
      removePending(err.config); // 在请求结束后，移除本次请求
    }
    return Promise.resolve(err.response);
  }
);

// 二、清理所有请求
// axios.js
/**
 * 清空 pending 中的请求（在路由跳转时调用）
 */
export const clearPending = () => {
  for (const [url, cancel] of pending) {
    cancel(url);
  }
  pending.clear();
};

// router.js
router.beforeEach((to, from, next) => {
  // 路由跳转，清除所有请求
  clearPending();
});

// 另一种方案
http.interceptors.request.use(
  (config) => {
    config.cancelToken = new axios.CancelToken((cancel) => {
      const url = window.location.href;
      window.axiosCancelArr[url] = cancel;
    });

    const token = DB.LS.get(TOKEN);
    if (token) {
      config.headers.Authorization = token;
    }
    return config;
  },
  (err) => {
    return Promise.reject(err);
  }
);

// router.js
useEffect(() => {
  // 批量取消 ajax
  // 防止切换路由，上一个路由页面数据请求成功但页面销毁了，控制台可能报错
  return () => {
    const { axiosCancelArr } = window;
    if (axiosCancelArr) {
      Object.keys(axiosCancelArr).map((key) =>
        axiosCancelArr[key]('axiosCancelArr')
      );
    }
  };
}, []);
